package utils

import (
	"fmt"
	_ "fmt"
	"github.com/go-redis/redis"
)

type MqSubscribe interface {
	subscribe()
}


type MqBody struct {
	channel string
	msg string
}

func subscribe(body MqBody)  {

}
// ReciveMsg  接受mq消息
func ReciveMsg(message *redis.Message)  {

	fmt.Println("接收到MQ消息是：",message.Payload)
	SendMsg(message.Payload)
}
